package org.devgframwork.datasync.core.support;

import com.rabbitmq.client.Channel;
import org.devgframwork.datasync.core.entity.TriggerConfig;
import org.springframework.context.ApplicationContext;
import org.springframework.jdbc.core.JdbcTemplate;

import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;

/**
 * @Description
 * @auther dh
 * @date 2022/1/5 14:43
 */
public class DataSourceMemory {
    public static ApplicationContext applicationContext = null;
    public static final Map<String, JdbcTemplate> jdbcTemplateMap = new ConcurrentHashMap<>();
    public static final Map<String, Channel> connectionChannelMap = new ConcurrentHashMap<>();
    public static final Map<String, String> sqlMap = new ConcurrentHashMap<>();
    public static final Map<String, TriggerConfig> triggerConfigMap = new ConcurrentHashMap<>();
    public static final int scheduleBatchSize = 1000;

}
